package hbec.kettle.etl.plugins.reader.mysqlreader;

public final class ParamKey {
	public final static String watchSumTableSql = "select object, id, identity, action, timestamp "
			+ "from {0} "
			+ "where id > {1, number, #} "
			+ "order by id limit 1000";
	
	public final static String checkpointTableSql = "select name, the_id from {0}";
	
	public final static String updateCheckpointTableSql = "insert into {0} (name, the_id) values (''{1}'', {2, number, #}) "
			+ "on duplicate key update the_id = values(the_id)";
	
	public final static String createSqliteTableSql = "create table {0} (id BIGINT PRIMARY KEY AUTOINCREMENT, name VARCHAR(255), line TEXT)";
	
	public final static String dropSqliteTableSql = "drop table if exists {0}";
	
	public final static String insertSqliteTableSql = "insert into {0} (name, line) values (''{1}'', ''{2}'')";
	
	public final static String querySqliteTableSql = "select id, line from {0} where name = ''{1}'' and id > {2, number, #} order by id limit 99"; 
}
